package com.feng.flink;

import com.feng.servie.MyService;
import org.apache.flink.api.common.functions.MapFunction;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

@Component
public class MyMapFunction implements MapFunction<String, String> {
    @Resource
    private MyService myService;

    @Override
    public String map(String value) throws Exception {
        return myService.test(value);
    }
}
